845b0c583e4f31be40c1d477534722fe6c65130f,modcluster/src/main/java/org/jboss/as/modcluster/ModClusterSubsystemAdd.java,ModClusterSubsystemAdd,performRuntime,#OperationContext#ModelNode#ModelNode#ServiceVerificationHandler#List#,54
Before Change
try {
// Add mod_cluster service
final ModClusterService service = new ModClusterService(operation.get(CommonAttributes.MOD_CLUSTER_CONFIG).clone());
newControllers.add(context.getServiceTarget().addService(ModClusterService.NAME, service)
// .addListener(new ResultHandler.ServiceStartListener(resultHandler))
.addDependency(WebSubsystemServices.JBOSS_WEB, WebServer.class, service.getWebServer())
.addListener(verificationHandler)
.setInitialMode(Mode.ACTIVE)
.install());
} catch (Throwable t) {
log.error("Error: " + t);
throw new OperationFailedException(new ModelNode().set(t.getLocalizedMessage()));
After Change
model.set(operation.get(CommonAttributes.MOD_CLUSTER_CONFIG));
}
protected void performRuntime(OperationContext context, ModelNode operation, ModelNode model, ServiceVerificationHandler verificationHandler, List<ServiceController<?>> newControllers) throws OperationFailedException {
String bindingRef = null;
if (operation.hasDefined(CommonAttributes.MOD_CLUSTER_CONFIG)) {
final ModelNode node = operation.get(CommonAttributes.MOD_CLUSTER_CONFIG);
if (node.hasDefined(CommonAttributes.ADVERTISE_SOCKET)) {
bindingRef = node.get(CommonAttributes.ADVERTISE_SOCKET).asString();
}
}
try {
// Add mod_cluster service
final ModClusterService service = new ModClusterService(operation.get(CommonAttributes.MOD_CLUSTER_CONFIG).clone());
final ServiceBuilder<ModCluster> serviceBuilder = context.getServiceTarget().addService(ModClusterService.NAME, service)
// .addListener(new ResultHandler.ServiceStartListener(resultHandler))
.addDependency(WebSubsystemServices.JBOSS_WEB, WebServer.class, service.getWebServer())
.addListener(verificationHandler)
.setInitialMode(Mode.ACTIVE);
if (bindingRef != null)
serviceBuilder.addDependency(SocketBinding.JBOSS_BINDING_NAME.append(bindingRef), SocketBinding.class, service.getBinding());
newControllers.add(serviceBuilder.install());
} catch (Throwable t) {
log.error("Error: " + t);
throw new OperationFailedException(new ModelNode().set(t.getLocalizedMessage()));